package com.heima.article.stream;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

/**
 * @Author : wuqiang
 * @since : 2022-10-21
 */
public interface ArticleStreamsProcessor {


    @Input("hot_article_score_topic")
    KStream<String, String> input();


    @Output("hot_article_score_result_topic")
    KStream<String, String> output();
}
